package com.zdd.ehe.service;

import org.apache.kafka.clients.consumer.ConsumerRecord;

/**
 * @version 1.0.0
 * @title: KafkaService
 * @author: HFLy
 * @description:
 * @date: 7/3/2023 下午4:33
 */
public interface KafkaService {
    //发送消息到 predict 主题中
    void sendToPredict(String message);

    //从 predict_result 接收消息
    void acceptFromPredictResult(ConsumerRecord<String, String> consumer);

    //发消息到 question
    void sendToQuestion(String message);

    //从 answer 接收消息
    void acceptFromAnswer(ConsumerRecord<String, String> consumer);
    //发送消息到 price
    void sendToPrice(String message);
    //从 price_predict 接收数据
    void acceptFromPricePredict(ConsumerRecord<String,String> consumer);
}
